package com.tensai.study.java.newconcept.typereactiveprogram.reactor.flux;

import org.junit.Test;
import reactor.core.publisher.Flux;

/**
 * @author Tensai
 */
public class SubscribeTest {


	@Test
	public void test4() {
		Flux<Integer> ints3 = Flux.range(1, 4);
		ints3.subscribe(System.out::println,
				error -> System.err.println("Error " + error),
				() -> System.out.println("Done"),
				sub -> sub.request(2));
	}
}
